640589c82b85a3efc1288ff4a3ffbb4cbb5c7d1a,portal-impl/test/unit/com/liferay/portal/cluster/ClusterExecutorImplTest.java,ClusterExecutorImplTest,testExecuteWithCallBack2,#,728
Before Change
// TimeoutException
ClusterRequest clusterRequest = ClusterRequest.createUnicastRequest(
null, new AddressImpl(new MockAddress()));
MockClusterResponseCallback mockClusterResponseCallback =
new MockClusterResponseCallback();
After Change
try {
clusterExecutorImpl = getClusterExecutorImpl(false, false);
String timestamp = String.valueOf(System.currentTimeMillis());
MethodHandler methodHandler = new MethodHandler(
testMethod1MethodKey, timestamp);
Address address = clusterExecutorImpl.getLocalClusterNodeAddress();
ClusterRequest clusterRequest = ClusterRequest.createUnicastRequest(
methodHandler, address);
MockClusterResponseCallback mockClusterResponseCallback =
new MockClusterResponseCallback();
clusterExecutorImpl.execute(
clusterRequest, mockClusterResponseCallback, 1000,
TimeUnit.MILLISECONDS);
ClusterNodeResponses clusterNodeResponses =
mockClusterResponseCallback.waitMessage();
assertFutureClusterResponsesWithoutException(
clusterNodeResponses, clusterRequest.getUuid(), timestamp,
address);
// TimeoutException
clusterRequest = ClusterRequest.createUnicastRequest(
null, new AddressImpl(new MockAddress()));
clusterExecutorImpl.execute(
clusterRequest, mockClusterResponseCallback, 1000,